package com.abing.permissionsys.limit;

import com.google.common.util.concurrent.RateLimiter;

import java.util.concurrent.TimeUnit;

public class RateLimiterDemo {


//    public static void main(String[] args) {
//        testAcquire();
//    }
//
//    public static void testAcquire() {
//        RateLimiter limiter = RateLimiter.create(10);
//
//        for (int i = 0; i < 10; i++) {
//            long timeOut = (long) 0.5;
//            boolean isValid = limiter.tryAcquire(timeOut, TimeUnit.SECONDS);
//            System.out.println("任务" + i + "执行是否有效:" + isValid);
//            if (!isValid) {
//                continue;
//            }
//            System.out.println("任务" + i + "在执行");
//        }
//        System.out.println("结束");
//    }
}
